package com.ziroom.crm.mq.core.support;

import com.ziroom.crm.mq.core.data.Message;
import com.ziroom.crm.mq.core.processor.QueueWrapper;

public class SimpleProcessorInvokerDelegate implements ProcessorInvokerDelegate {

    /**
     * 执行前置触发
     *
     * @param queueWrapper
     * @param message
     */
    @Override
    public void preSendInvoke(QueueWrapper queueWrapper, Message message) {
        ProcessorInvoker.preSendInvoke(queueWrapper, message);
    }

    /**
     * 执行后置处理
     *
     * @param queueWrapper
     * @param message
     */
    @Override
    public void postSendInvoke(QueueWrapper queueWrapper, Message message) {
        ProcessorInvoker.postSendInvoke(queueWrapper, message);
    }

    /**
     * 执行重发前置处理
     *
     * @param queueWrapper
     * @param message
     */
    @Override
    public void preReSendInvoke(QueueWrapper queueWrapper, Message message) {
        ProcessorInvoker.preReSendInvoke(queueWrapper, message);

    }

    /**
     * 执行重发后置处理
     *
     * @param queueWrapper
     * @param message
     */
    @Override
    public void postReSendInvoke(QueueWrapper queueWrapper, Message message) {
        ProcessorInvoker.postReSendInvoke(queueWrapper, message);
    }

    /**
     * 执行前置触发
     *
     * @param queueWrapper
     * @param message
     */
    @Override
    public void preConsumeInvoke(QueueWrapper queueWrapper, Message message) {
        ProcessorInvoker.preConsumeInvoke(queueWrapper, message);
    }

    /**
     * 执行后置处理
     *
     * @param queueWrapper
     * @param message
     */
    @Override
    public void postConsumeInvoke(QueueWrapper queueWrapper, Message message) {
        ProcessorInvoker.postConsumeInvoke(queueWrapper, message);
    }

    /**
     * 执行重发前置处理
     *
     * @param queueWrapper
     * @param message
     */
    @Override
    public void preReConsumeInvoke(QueueWrapper queueWrapper, Message message) {
        ProcessorInvoker.preReConsumeInvoke(queueWrapper, message);
    }

    /**
     * 执行重发后置处理
     *
     * @param queueWrapper
     * @param message
     */
    @Override
    public void postReConsumeInvoke(QueueWrapper queueWrapper, Message message) {
        ProcessorInvoker.postReConsumeInvoke(queueWrapper, message);
    }
}
